package com.earthea.chatbot.service;

import com.earthea.chatbot.entity.domain.Message;
import com.earthea.chatbot.entity.response.MessageRsp;
import com.earthea.chatbot.entity.response.PublishMessageRsp;
import reactor.core.publisher.Flux;

public interface MessageService {

    /**
     * 查询所有消息
     *
     * @return 查询结果
     */
    MessageRsp selectByChat(Message message);

    /**
     * 发送消息
     *
     * @param message 消息对象
     * @return 结果
     */
    Flux<String> stream(Message message);

    /**
     * 发送消息
     *
     * @param message 消息对象
     * @return 结果
     */
    PublishMessageRsp insert(Message message);
}
